/**
 *  定义数据库连接
 */
const mysql = require('mysql')
const tools = require('../public/tools')

const pool = mysql.createPool({
  host: 'bdm246562380.my3w.com',
  user: 'bdm246562380',
  password: 'p081742lh',
  database: 'bdm246562380_db'
})

/**
 *  通过链接池链接数据库
 * @param sql  业务sql
 * @param params   业务sql需要的参数
 * @param res   用于处理链接并返回json参数
 */
function test(sql, params, res) {
  const p = params
  pool.getConnection(function(err, con) {
    if (err) throw err
    con.query(sql, p || [], function(err, data, fields) {
      if (err) throw err
      con.release()
      tools.sendJson(res, data)
    })
  })
}
module.exports = test
